package com.csx.governance.traffic.mq.rocketmq;

import org.apache.rocketmq.spring.core.RocketMQReplyListener;

/**
 * 消费并且回复消息
 * @author cuisongxu
 * @date 2023/2/28 17:14
 */
public class TrafficRocketMQReplyListener implements RocketMQReplyListener<String, String> {

    @Override
    public String onMessage(String message) {
        System.out.println("TrafficRocketMQReplyListener#onMessage");
        return null;
    }
}
